package io.gitee.redismq.api;

import java.util.HashMap;
import java.util.Map;

/**
 * @Author: 孙浩
 * @CreateTime: 2025-03-06 09:43:20
 */
public interface StreamTemplate {
    /**
     * 发送消息到指定 Stream
     *
     * @param streamKey Stream 名称（分组标识）
     * @param payload   消息内容  （自动包装为 Map）
     */
    <T> void sendMessage(final String streamKey, final T payload);
    /**
     * 发送消息到指定 Stream
     *
     * @param streamKey Stream 名称（分组标识）
     * @param payload   消息内容  （自动包装为 Map）
     */
     <T> void sendMessage(final String streamKey, final T payload,Map<String, Object> headers);
}
